//package org.cy.websocket.stomp;
//
//import org.cy.websocket.stomp.messaging.StringMessageConverter;
//import org.junit.jupiter.api.DisplayName;
//import org.junit.jupiter.api.Test;
//
///**
// * Created in 2021-05-08 20:46
// *
// * @author cao.yong
// */
//@DisplayName("Stomp Client Test")
//public class StompClientTestCase {
//
//    @DisplayName("Stomp Client Connect")
//    @Test
//    void connect() throws InterruptedException {
//        StompHeaders headers = new StompHeaders();
//        headers.add("deviceName", "");
//        headers.add("deviceType", "0");
//        headers.add("deviceInit", "true");
//        headers.add("devicePair", "");
//        StompClient client = StompClient.init().url("ws://8.142.20.229:8080/comm")
//                .heartbeat(0, 1000)
//                .onConnected(message -> {
//                    String body = StringMessageConverter.fromMessage(message);
//                    System.out.println(body);
//                });
//        client.connect(headers);
//        Thread.sleep(10000);
//    }
//}
